package com.xmut.mall.product.listener;

import lombok.extern.slf4j.Slf4j;


//@Component
@Slf4j
public class KafkaCanalListener {

//    @KafkaListener(topics = {"example"})
//    public void onMessage1(ConsumerRecord<?, ?> consumerRecord) {
//        Optional<?> optional = Optional.ofNullable(consumerRecord.value());
//        if (optional.isPresent()) {
//            Object msg = optional.get();
//            log.info("得到的消息{}",msg);
//        }
//    }
}
